package com.grep.extra.factory.handle;

import java.util.List;

import com.grep.extra.factory.data.IDataQueue;
/**
 * 通用数据分析处理接口
 * @author tiamsw
 *
 * @param <K>	流入的数据类型
 * @param <T>	流出的数据类型
 */

public interface IHandler<K,T> {

	/**
	 * 初始化数据
	 */
	public void init(IDataQueue<K> task,IDataQueue<T> data) ;
	
	/**
	 * 获取要处理的任务队列
	 * @return
	 */
	public IDataQueue<K> getTask() ;
	
	/**
	 * 数据加工,并返回加工后的值
	 */
	public List<T> process(K k) ;
}
